package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object A06_行动算子_Save {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    val rdd = sc.textFile("data/a.txt").map(_.toUpperCase)
    // 将结果数据保存HDFS系统中  本地路径
   // rdd.saveAsTextFile("hdfs://linux01:8020/data/a_upper/")
    rdd.saveAsObjectFile("data/a_upper2/")
  }

}
